9c249f987be2851366f8c014557d3539d9b62137,src/main/java/org/jetlang/web/WebSocketConnection.java,WebSocketConnection,scheduleWithFixedDelay,#Runnable#number#number#TimeUnit#,159
Before Change
@Override
public Disposable scheduleWithFixedDelay(Runnable runnable, long l, long l1, TimeUnit timeUnit) {
Disposable disposable = readFiber.scheduleWithFixedDelay(runIfActive(runnable), l, l1, timeUnit);
addIfActive(disposable);
return disposable;
}
After Change
@Override
public Disposable scheduleWithFixedDelay(Runnable runnable, long initialDelay, long delay, TimeUnit timeUnit) {
return register(readFiber.scheduleWithFixedDelay(runIfActive(runnable), initialDelay, delay, timeUnit));
}
private Disposable register(Disposable disposable) {